<?php

/**
 * @author heshun
 */

require_library('framework.db');

class Insert {

    private $settings = NULL;

    /**
     * 如果客户端来一个SQL，则缓存系统需要实现查询分析器
     * 如果客户端采用ORM，则这里实现一些拼装，参考eshequn的select类
     * @param <type> $sql
     */
    public function __construct($settings)
    {
        $this->settings = $settings;
    }

    public function execute($sql)
    {
        // 如果实现了da服务器，则调用daserver，因为不仅仅是删除一条记录，还需要管理缓存的过期，更新等
        //self::_request($daServer, $sql);
        // 这里直接取数据库
        $result = DB::getInstance($this->settings)->query($sql);
        if (!$result)
        {
            return false;
        }

        return DB::getInstance($this->settings)->affectedRows();
    }
}
?>
